package com.simple.mq.test.config;

import com.simple.mq.boot.starter.annotation.SimpleMqInit;
import com.simple.mq.common.entity.RegisterQueueInfo;
import com.simple.mq.sdk.register.SimpleMqInitQueuesService;

import java.util.ArrayList;
import java.util.List;

/**
 * 项目: simple-mq
 * <p>
 * 功能描述:
 *
 * @author: WuChengXing
 * @create: 2023-09-17 10:52
 **/
@SimpleMqInit
public class SimpleMqQueuesConfig implements SimpleMqInitQueuesService {

    @Override
    public List<RegisterQueueInfo> initQueues() {
        List<RegisterQueueInfo> registerQueueInfos = new ArrayList<>();
        RegisterQueueInfo springQueue = new RegisterQueueInfo("springQueue", "spring.queue.#", true);
        registerQueueInfos.add(springQueue);
        return registerQueueInfos;
    }


}
